package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.pojo.Point;
import com.navinfo.tripanalysis.common.pojo.Point0200;
import com.navinfo.tripanalysis.offline.pojo.Abnormal0200DataDetail;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.util.AccumulatorV2;
import scala.Tuple2;

import java.util.List;

/**
 * 数据清洗：清洗0200服务
 */
public interface DataCleaning0200Service {
    JavaPairRDD<Long, Tuple2<Abnormal0200DataDetail, List<Point0200>>> getAbnormal0200Data(JavaPairRDD<Long, List<Point>> pointsRdd, AccumulatorV2<String, String> accumulator);
}
